package dao;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;



import model.Usuario;

public class UsuarioDao {

	private Conexao con;
	private Statement stmt;
	private boolean sucesso = false;


	public UsuarioDao() {
		con = new Conexao();		
		try {
			stmt = (Statement) con.getCon().createStatement();
		} catch (SQLException ex) {
			ex.printStackTrace();
			
		}		
	}
	



	public Usuario salvaUsuario(Usuario login) {   
		Usuario user= new Usuario();
		try {           
			ResultSet rs = stmt.executeQuery("SELECT *from usuario where login='" + login.getLogin() + "'and senha='" + login.getSenha() + "'");
			while (rs.next()) {
				user.setLogin(rs.getString("login"));
				user.setCNPJ(rs.getString("CNPJ"));
			}

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			con.fecharConexao();
		}
		return user;
	}
	
	//usado para alterar a senha do usuario
	public boolean checksenhaAtual(String CNPJ, String senhaAtual){
		try {           
			ResultSet rs = stmt.executeQuery("SELECT *from usuario where CNPJ='" + CNPJ + "'and senha='" + senhaAtual + "'");
			sucesso = rs.next();

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			con.fecharConexao();
		}
		return sucesso;
	}

	public boolean alterar(String CNPJ, String senha ) {

		String alterarUsuario = ("UPDATE usuario SET senha=? WHERE CNPJ=?");
		try {
			PreparedStatement pstmt = con.getCon().prepareStatement(alterarUsuario);
			pstmt.setString(1, senha);
			pstmt.setString(2, CNPJ);           

			pstmt.executeUpdate();
			sucesso = true;
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			con.fecharConexao();
		}
		return sucesso;
	}
}
